package com.example.d10_homework.homework02;


import java.io.*;
import java.net.Socket;

/**
 * 消费者
 */
public class Consumer {
    public static void main(String[] args) throws Exception {
        // 创建Socket连接到本地主机的指定端口
        Socket socket = new Socket("127.0.0.1", 5672);

        // 获取Socket的输出流,并包装为BufferedWriter以便于写入文本数据
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));

        // 向服务器发送标识,表明这是一个消费者
        bw.write("consumer");
        bw.newLine();
        bw.flush();

        // 获取Socket的输入流,并包装为BufferedReader以便于读取文本数据
        // 当中使用到了转换流
        BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));

        // 无限循环等待并处理从服务器接收的数据
        while (true) {
            String line;
            // 读取并打印从服务器接收到的每一行数据
            while ((line = br.readLine()) != null) {
                System.out.println(line);
            }
        }
    }
}
